package com.bzm.config.im;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import io.netty.channel.Channel;

public class CacheUtil {

	/**
     * 线程池
     */
    public static ExecutorService executorService = Executors.newFixedThreadPool(3);
    /**
     * 缓存channel
     */
    public static Map<String, Channel> cacheChannel = new ConcurrentHashMap(new HashMap<>());
	
    public static void main(String[] args) {
		
    	String  toChannelId = "65412344";
    	Channel channel = CacheUtil.cacheChannel.get(toChannelId);
        if (null == channel) {
            return;
        }
        String msg = "";
        channel.writeAndFlush(msg);
        	
	}
}
